package com.bd08.flink.demo.jing

import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.streaming.api.scala.createTypeInformation

object RepartitionDemo  extends App {

  val benv = ExecutionEnvironment.getExecutionEnvironment
  val ds=benv.generateSequence(1,10)
  val result=ds.mapPartition(in=>{
    in.map((_,1))
  })
  result.print()


}
